package com.intretech.tj.mqtt.pipeline;

import com.intretech.tj.global.parent.PipelineParent;
import io.vertx.mutiny.mqtt.messages.MqttPublishMessage;
import jakarta.enterprise.context.ApplicationScoped;

/**
 * 主题管道<br/>
 * 该管道会后于{@link MessagePipeline}运行<br/>
 * key:主题<br/>
 * type:{@link MqttPublishMessage} 匹配该主题的消息
 */
@ApplicationScoped
public class TopicPipeline extends PipelineParent<MqttPublishMessage> {
}
